package com.ling.luo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 基本消息发送和接收
 *
 * @author luohoujian
 * @since 2021/05/25
 */
@SpringBootApplication
@EnableCaching
@RestController
public class RocketMQDemoApplication {

    /**
     * 4.消息发送样例
     * 4.1基本样例
     * 4.1.1消息发送
     * 1）发送同步消息
     * 2）发送异步消息
     * 3）单向发送消息
     * 4.1.2消费消息
     * 4.2顺序消息
     * 4.3延时消息
     * 4.4批量消息
     * 4.5过滤消息
     * 4.6事务消息
     * @param args
     */
    public static void main(String[] args) {
        SpringApplication.run(RocketMQDemoApplication.class, args);
    }

    /**
     * 判断程序是否启动完成
     * @return
     */
    @GetMapping("/")
    public String index() {
        return "RocketMQDemoApplication";
    }

}
